/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package communicator;

import base.SynchronousQueue;
import debug.DebugFrame;

/**
 *
 * @author MR.BLACK
 */
public class CommunicationProcessor extends Thread{
    private SynchronousQueue messageQueue;
    public CommunicationProcessor(SynchronousQueue msgQueue){
        this.messageQueue = msgQueue;
    }
    
    @Override
    public void run(){
        DebugFrame.receivMsg("COMMUNICATION PROCESSOR RUNNING..." + "\n");
        new Receiver().start();
        new Sender(messageQueue).start();
    }
}

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */


